package com.zdd.ehe.service.impl;

import com.zdd.ehe.service.KafkaService;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.stereotype.Service;

/**
 * @version 1.0.0
 * @title: KafKaServiceImplSimple
 * @author: HFLy
 * @description:
 * @date: 8/3/2023 下午2:47
 */
@Service
public class KafKaServiceImplSimple implements KafkaService {
    @Override
    public void sendToPredict(String message) {

    }

    @Override
    public void acceptFromPredictResult(ConsumerRecord<String, String> consumer) {

    }

    @Override
    public void sendToQuestion(String message) {

    }

    @Override
    public void acceptFromAnswer(ConsumerRecord<String, String> consumer) {

    }

    @Override
    public void sendToPrice(String message) {

    }

    @Override
    public void acceptFromPricePredict(ConsumerRecord<String, String> consumer) {

    }
}
